package com.avoid.easymqtt.remoting;

import com.avoid.easymqtt.mqtt.MqttRequestProcessor;

import java.util.concurrent.ExecutorService;

/**
 * 远程服务器
 *
 * @author avoid@fiture.com
 * @date 2022/4/29
 * @motto Life is so short,do something to make yourself happy,such as coding
 */
public interface RemotingServer extends RemotingService{

    void registerProcessor(final int requestCode, final MqttRequestProcessor processor,
        final ExecutorService executor);

    void registerDefaultProcessor(final MqttRequestProcessor processor, final ExecutorService executor);

}
